package com.fy.common.model.mq;

import lombok.Data;
import org.slf4j.MDC;

import java.util.Map;

@Data
public class KafkaBaseMessage {

    /**
     * slf4j的MDC信息
     */
    private Map<String,String> mdc;

    public KafkaBaseMessage() {
        this.mdc = MDC.getCopyOfContextMap();
    }


}
